261cb3577d094c3c3a3cf74829e84608249b4034,src/main/java/com/continuuity/data/operation/ttqueue/TTQueueNewOnVCTable.java,TTQueueNewOnVCTable,unack,#QueueEntryPointer#QueueConsumer#ReadPointer#,340
Before Change
new byte[][] {new EntryConsumerMeta(EntryConsumerMeta.EntryState.CLAIMED, 0).getBytes(),
Bytes.toBytes(entryPointer.getEntryId()), Bytes.toBytes(0)});
if(consumer.isStateful()) {
getQueueStateImpl(consumer.getQueueState()).setActiveEntryId(entryPointer.getEntryId());
}
}
static long groupId = 0;
After Change
}
// Set unack state
queueState.setActiveEntryId(entryPointer.getEntryId());
queueState.setActiveEntryTries(0);
// Write unack state